-- sink
create table hdp_lbg_supin_dwd_zp_n_star_app_log (
    ts string comment '事件时间格式yyyy-MM-dd HH:mm:ss.SSS',
    host string comment '服务地址',
    log_level string comment '日志级别',
    service_name string comment '服务名称',
    thread_name string comment '线程名称',
    code_file string comment '代码文件',
    code_line string comment '代码行数',
    code_method string comment '代码方法',
    code_class string comment '代码类',
    trace_id string comment '',
    msg_content string comment ''
)
with(
'connector' = 'kafka',
'topic' = 'hdp_lbg_supin_dwd_zp_n_star_app_log',
'properties.bootstrap.servers' = '10.178.10.8:9092,10.178.10.10:9092,10.178.10.11:9092,10.178.10.12:9092,10.178.10.13:9092',
'scan.startup.mode' = 'group-offsets',
'format' = 'json'
);